package com.company.wushuo.justfortest.reactive;

import android.support.annotation.NonNull;

/**
 * Created by wushuo on 2021/4/3.
 */

public interface ObservableEmitter<T> extends Emitter<T> {

    /**
     * Ensures that calls to onNext, onError and onComplete are properly serialized.
     * @return the serialized ObservableEmitter
     */
    @NonNull
    ObservableEmitter<T> serialize();
}
